package com.ynet.middleground.riskmanage.mq;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * @author liwq
 * @description 日照港指令相关通道
 * @date 2025-05-16 13:45
 */
public interface RzgCommandSource {
    String TRANSFER_COMMAND_OUT = "transfer_command_out";
    String JKZTFK_TO_DZCD_KHJGZT = "jkztfk-to-dzcd-khjgzt";

    @Output(RzgCommandSource.TRANSFER_COMMAND_OUT)
    MessageChannel sendTransferResultToChannel();

    @Output(RzgCommandSource.JKZTFK_TO_DZCD_KHJGZT)
    MessageChannel sendJkztfkToDzcdKhjgzt();
}
